package com.cesce.batch.cobros.items;

import java.math.BigDecimal;
import java.util.HashSet;
import java.util.Set;

import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
import org.springframework.batch.item.ItemProcessor;

import com.cesce.batch.cobros.reverse.Cobcomunicados;
import com.cesce.batch.cobros.reverse.Cobparametros;
import com.cesce.batch.cobros.reverse.Cobregistro;



public class RegistroXlsProcessor implements ItemProcessor<RegistroFTP, Cobregistro> {

	protected final Log logger = LogFactory.getLog(getClass());

	
	public Cobregistro process(RegistroFTP item) throws Exception {
		

		Set<Cobcomunicados> comunicados = new HashSet<Cobcomunicados>(); 
		Cobcomunicados comuni = new Cobcomunicados();
		
		
		
		comuni.setCodigocesce("codCesce");
		comuni.setNif("11111");
		comuni.setDivisa(new BigDecimal(11));
		comuni.setNumfactura("NFAct1");
		
		comunicados.add(comuni);

		logger.info("Thread: " + Thread.currentThread().getId()+ ", procesando item " +  comuni);		 

		
		comuni = new Cobcomunicados();
////		
////
		comuni.setCodigocesce("codCesce2");
		comuni.setNif("22222");
		comuni.setDivisa(new BigDecimal(22));
		comuni.setNumfactura("NFAct2");
////		
		comunicados.add(comuni);
//
		logger.info("Thread: " + Thread.currentThread().getId()+ ", procesando item " +  comuni);		 

		
		Cobregistro rc = item.getIdRegistro();
		
		Cobparametros params = rc.getIdcodparametro();
		
		logger.info("Thread: " + Thread.currentThread().getId()+ ", procesando params " +  params);
		
		rc.setCobcomunicadoss(comunicados);
		rc.setLineaserroneas(new BigDecimal(0));
		rc.setLineastotales(new BigDecimal(2));


		return rc;
	}
	
	
}
